
/*
 * Copyright (C) Igor Sysoev
 * Copyright (C) Nginx, Inc.
 */


#include <ngx_config.h>
#include <ngx_core.h>
#include <ngx_http.h>

#include <GeoIP.h>
#include <GeoIPCity.h>


#define NGX_GEOIP_COUNTRY_CODE  0
#define NGX_GEOIP_COUNTRY_CODE3 1
#define NGX_GEOIP_COUNTRY_NAME  2


typedef struct
{
    GeoIP *country;
#if (T_GEO)
    GeoIP *region;
#endif
    GeoIP       *org;
    GeoIP       *city;
    ngx_array_t *proxies; /* array of ngx_cidr_t */
    ngx_flag_t   proxy_recursive;
#if (NGX_HAVE_GEOIP_V6)
    unsigned country_v6 : 1;
    unsigned org_v6     : 1;
    unsigned city_v6    : 1;
#endif
} ngx_http_geoip_conf_t;


typedef struct
{
    ngx_str_t *name;
    uintptr_t  data;
} ngx_http_geoip_var_t;


typedef const char *(*ngx_http_geoip_variable_handler_pt)(GeoIP *, u_long addr);


ngx_http_geoip_variable_handler_pt ngx_http_geoip_country_functions[] = {
    GeoIP_country_code_by_ipnum,
    GeoIP_country_code3_by_ipnum,
    GeoIP_country_name_by_ipnum,
};


#if (NGX_HAVE_GEOIP_V6)

typedef const char *(*ngx_http_geoip_variable_handler_v6_pt)(GeoIP *,
                                                             geoipv6_t addr);


ngx_http_geoip_variable_handler_v6_pt ngx_http_geoip_country_v6_functions[] = {
    GeoIP_country_code_by_ipnum_v6,
    GeoIP_country_code3_by_ipnum_v6,
    GeoIP_country_name_by_ipnum_v6,
};

#endif


static ngx_int_t ngx_http_geoip_country_variable(ngx_http_request_t        *r,
                                                 ngx_http_variable_value_t *v,
                                                 uintptr_t data);
#if (T_GEO)
static ngx_int_t ngx_http_geoip_region_variable(ngx_http_request_t        *r,
                                                ngx_http_variable_value_t *v,
                                                uintptr_t data);
#endif
static ngx_int_t ngx_http_geoip_org_variable(ngx_http_request_t        *r,
                                             ngx_http_variable_value_t *v,
                                             uintptr_t                  data);
static ngx_int_t ngx_http_geoip_city_variable(ngx_http_request_t        *r,
                                              ngx_http_variable_value_t *v,
                                              uintptr_t                  data);
static ngx_int_t ngx_http_geoip_region_name_variable(
    ngx_http_request_t *r, ngx_http_variable_value_t *v, uintptr_t data);
static ngx_int_t ngx_http_geoip_city_float_variable(
    ngx_http_request_t *r, ngx_http_variable_value_t *v, uintptr_t data);
static ngx_int_t    ngx_http_geoip_city_int_variable(ngx_http_request_t        *r,
                                                     ngx_http_variable_value_t *v,
                                                     uintptr_t data);
static GeoIPRecord *ngx_http_geoip_get_city_record(ngx_http_request_t *r);

static ngx_int_t ngx_http_geoip_add_variables(ngx_conf_t *cf);
static void     *ngx_http_geoip_create_conf(ngx_conf_t *cf);
static char     *ngx_http_geoip_init_conf(ngx_conf_t *cf, void *conf);
static char     *ngx_http_geoip_country(ngx_conf_t *cf, ngx_command_t *cmd,
                                        void *conf);
#if (T_GEO)
static char *ngx_http_geoip_region(ngx_conf_t *cf, ngx_command_t *cmd,
                                   void *conf);
#endif
static char *ngx_http_geoip_org(ngx_conf_t *cf, ngx_command_t *cmd, void *conf);
static char *ngx_http_geoip_city(ngx_conf_t *cf, ngx_command_t *cmd,
                                 void *conf);
static char *ngx_http_geoip_proxy(ngx_conf_t *cf, ngx_command_t *cmd,
                                  void *conf);
static ngx_int_t ngx_http_geoip_cidr_value(ngx_conf_t *cf, ngx_str_t *net,
                                           ngx_cidr_t *cidr);
static void      ngx_http_geoip_cleanup(void *data);


static ngx_command_t ngx_http_geoip_commands[] = {

    {ngx_string("geoip_country"), NGX_HTTP_MAIN_CONF | NGX_CONF_TAKE12,
     ngx_http_geoip_country, NGX_HTTP_MAIN_CONF_OFFSET, 0, NULL},

#if (T_GEO)
    {ngx_string("geoip_region"), NGX_HTTP_MAIN_CONF | NGX_CONF_TAKE12,
     ngx_http_geoip_region, NGX_HTTP_MAIN_CONF_OFFSET, 0, NULL},
#endif

    {ngx_string("geoip_org"), NGX_HTTP_MAIN_CONF | NGX_CONF_TAKE12,
     ngx_http_geoip_org, NGX_HTTP_MAIN_CONF_OFFSET, 0, NULL},

    {ngx_string("geoip_city"), NGX_HTTP_MAIN_CONF | NGX_CONF_TAKE12,
     ngx_http_geoip_city, NGX_HTTP_MAIN_CONF_OFFSET, 0, NULL},

    {ngx_string("geoip_proxy"), NGX_HTTP_MAIN_CONF | NGX_CONF_TAKE1,
     ngx_http_geoip_proxy, NGX_HTTP_MAIN_CONF_OFFSET, 0, NULL},

    {ngx_string("geoip_proxy_recursive"), NGX_HTTP_MAIN_CONF | NGX_CONF_FLAG,
     ngx_conf_set_flag_slot, NGX_HTTP_MAIN_CONF_OFFSET,
     offsetof(ngx_http_geoip_conf_t, proxy_recursive), NULL},

    ngx_null_command};


static ngx_http_module_t ngx_http_geoip_module_ctx = {
    ngx_http_geoip_add_variables, /* preconfiguration */
    NULL,                         /* postconfiguration */

    ngx_http_geoip_create_conf, /* create main configuration */
    ngx_http_geoip_init_conf,   /* init main configuration */

    NULL, /* create server configuration */
    NULL, /* merge server configuration */

    NULL, /* create location configuration */
    NULL  /* merge location configuration */
};


ngx_module_t ngx_http_geoip_module = {
    NGX_MODULE_V1,
    &ngx_http_geoip_module_ctx, /* module context */
    ngx_http_geoip_commands,    /* module directives */
    NGX_HTTP_MODULE,            /* module type */
    NULL,                       /* init master */
    NULL,                       /* init module */
    NULL,                       /* init process */
    NULL,                       /* init thread */
    NULL,                       /* exit thread */
    NULL,                       /* exit process */
    NULL,                       /* exit master */
    NGX_MODULE_V1_PADDING};


static ngx_http_variable_t ngx_http_geoip_vars[] = {

    {ngx_string("geoip_country_code"), NULL, ngx_http_geoip_country_variable,
     NGX_GEOIP_COUNTRY_CODE, 0, 0},

    {ngx_string("geoip_country_code3"), NULL, ngx_http_geoip_country_variable,
     NGX_GEOIP_COUNTRY_CODE3, 0, 0},

    {ngx_string("geoip_country_name"), NULL, ngx_http_geoip_country_variable,
     NGX_GEOIP_COUNTRY_NAME, 0, 0},

#if (T_GEO)
    {ngx_string("geoip_region_country_code"), NULL,
     ngx_http_geoip_region_variable, offsetof(GeoIPRegion, country_code), 0, 0},

    {ngx_string("geoip_region_region"), NULL, ngx_http_geoip_region_variable,
     offsetof(GeoIPRegion, region), 0, 0},
#endif

    {ngx_string("geoip_org"), NULL, ngx_http_geoip_org_variable, 0, 0, 0},

    {ngx_string("geoip_city_continent_code"), NULL,
     ngx_http_geoip_city_variable, offsetof(GeoIPRecord, continent_code), 0, 0},

    {ngx_string("geoip_city_country_code"), NULL, ngx_http_geoip_city_variable,
     offsetof(GeoIPRecord, country_code), 0, 0},

    {ngx_string("geoip_city_country_code3"), NULL, ngx_http_geoip_city_variable,
     offsetof(GeoIPRecord, country_code3), 0, 0},

    {ngx_string("geoip_city_country_name"), NULL, ngx_http_geoip_city_variable,
     offsetof(GeoIPRecord, country_name), 0, 0},

    {ngx_string("geoip_region"), NULL, ngx_http_geoip_city_variable,
     offsetof(GeoIPRecord, region), 0, 0},

    {ngx_string("geoip_region_name"), NULL, ngx_http_geoip_region_name_variable,
     0, 0, 0},

    {ngx_string("geoip_city"), NULL, ngx_http_geoip_city_variable,
     offsetof(GeoIPRecord, city), 0, 0},

    {ngx_string("geoip_postal_code"), NULL, ngx_http_geoip_city_variable,
     offsetof(GeoIPRecord, postal_code), 0, 0},

    {ngx_string("geoip_latitude"), NULL, ngx_http_geoip_city_float_variable,
     offsetof(GeoIPRecord, latitude), 0, 0},

    {ngx_string("geoip_longitude"), NULL, ngx_http_geoip_city_float_variable,
     offsetof(GeoIPRecord, longitude), 0, 0},

    {ngx_string("geoip_dma_code"), NULL, ngx_http_geoip_city_int_variable,
     offsetof(GeoIPRecord, dma_code), 0, 0},

    {ngx_string("geoip_area_code"), NULL, ngx_http_geoip_city_int_variable,
     offsetof(GeoIPRecord, area_code), 0, 0},

    ngx_http_null_variable};


static u_long
ngx_http_geoip_addr(ngx_http_request_t *r, ngx_http_geoip_conf_t *gcf)
{
    ngx_addr_t          addr;
    ngx_array_t        *xfwd;
    struct sockaddr_in *sin;

    addr.sockaddr = r->connection->sockaddr;
    addr.socklen  = r->connection->socklen;
    /* addr.name = r->connection->addr_text; */

    xfwd = &r->headers_in.x_forwarded_for;

    if (xfwd->nelts > 0 && gcf->proxies != NULL)
    {
        (void)ngx_http_get_forwarded_addr(r, &addr, xfwd, NULL, gcf->proxies,
                                          gcf->proxy_recursive);
    }

#if (NGX_HAVE_INET6)

    if (addr.sockaddr->sa_family == AF_INET6)
    {
        u_char          *p;
        in_addr_t        inaddr;
        struct in6_addr *inaddr6;

        inaddr6 = &((struct sockaddr_in6 *)addr.sockaddr)->sin6_addr;

        if (IN6_IS_ADDR_V4MAPPED(inaddr6))
        {
            p = inaddr6->s6_addr;

            inaddr = p[12] << 24;
            inaddr += p[13] << 16;
            inaddr += p[14] << 8;
            inaddr += p[15];

            return inaddr;
        }
    }

#endif

    if (addr.sockaddr->sa_family != AF_INET)
    {
        return INADDR_NONE;
    }

    sin = (struct sockaddr_in *)addr.sockaddr;
    return ntohl(sin->sin_addr.s_addr);
}


#if (NGX_HAVE_GEOIP_V6)

static geoipv6_t
ngx_http_geoip_addr_v6(ngx_http_request_t *r, ngx_http_geoip_conf_t *gcf)
{
    ngx_addr_t           addr;
    ngx_array_t         *xfwd;
    in_addr_t            addr4;
    struct in6_addr      addr6;
    struct sockaddr_in  *sin;
    struct sockaddr_in6 *sin6;

    addr.sockaddr = r->connection->sockaddr;
    addr.socklen  = r->connection->socklen;
    /* addr.name = r->connection->addr_text; */

    xfwd = &r->headers_in.x_forwarded_for;

    if (xfwd->nelts > 0 && gcf->proxies != NULL)
    {
        (void)ngx_http_get_forwarded_addr(r, &addr, xfwd, NULL, gcf->proxies,
                                          gcf->proxy_recursive);
    }

    switch (addr.sockaddr->sa_family)
    {
    case AF_INET:
        /* Produce IPv4-mapped IPv6 address. */
        sin   = (struct sockaddr_in *)addr.sockaddr;
        addr4 = ntohl(sin->sin_addr.s_addr);

        ngx_memzero(&addr6, sizeof(struct in6_addr));
        addr6.s6_addr[10] = 0xff;
        addr6.s6_addr[11] = 0xff;
        addr6.s6_addr[12] = addr4 >> 24;
        addr6.s6_addr[13] = addr4 >> 16;
        addr6.s6_addr[14] = addr4 >> 8;
        addr6.s6_addr[15] = addr4;
        return addr6;

    case AF_INET6:
        sin6 = (struct sockaddr_in6 *)addr.sockaddr;
        return sin6->sin6_addr;

    default: return in6addr_any;
    }
}

#endif


static ngx_int_t
ngx_http_geoip_country_variable(ngx_http_request_t        *r,
                                ngx_http_variable_value_t *v, uintptr_t data)
{
    ngx_http_geoip_variable_handler_pt handler =
        ngx_http_geoip_country_functions[data];
#if (NGX_HAVE_GEOIP_V6)
    ngx_http_geoip_variable_handler_v6_pt handler_v6 =
        ngx_http_geoip_country_v6_functions[data];
#endif

    const char            *val;
    ngx_http_geoip_conf_t *gcf;

    gcf = ngx_http_get_module_main_conf(r, ngx_http_geoip_module);

    if (gcf->country == NULL)
    {
        goto not_found;
    }

#if (NGX_HAVE_GEOIP_V6)
    val = gcf->country_v6
              ? handler_v6(gcf->country, ngx_http_geoip_addr_v6(r, gcf))
              : handler(gcf->country, ngx_http_geoip_addr(r, gcf));
#else
    val = handler(gcf->country, ngx_http_geoip_addr(r, gcf));
#endif

    if (val == NULL)
    {
        goto not_found;
    }

    v->len          = ngx_strlen(val);
    v->valid        = 1;
    v->no_cacheable = 0;
    v->not_found    = 0;
    v->data         = (u_char *)val;

    return NGX_OK;

not_found:

    v->not_found = 1;

    return NGX_OK;
}


static ngx_int_t
ngx_http_geoip_org_variable(ngx_http_request_t *r, ngx_http_variable_value_t *v,
                            uintptr_t data)
{
    size_t                 len;
    char                  *val;
    ngx_http_geoip_conf_t *gcf;

    gcf = ngx_http_get_module_main_conf(r, ngx_http_geoip_module);

    if (gcf->org == NULL)
    {
        goto not_found;
    }

#if (NGX_HAVE_GEOIP_V6)
    val = gcf->org_v6
              ? GeoIP_name_by_ipnum_v6(gcf->org, ngx_http_geoip_addr_v6(r, gcf))
              : GeoIP_name_by_ipnum(gcf->org, ngx_http_geoip_addr(r, gcf));
#else
    val = GeoIP_name_by_ipnum(gcf->org, ngx_http_geoip_addr(r, gcf));
#endif

    if (val == NULL)
    {
        goto not_found;
    }

    len     = ngx_strlen(val);
    v->data = ngx_pnalloc(r->pool, len);
    if (v->data == NULL)
    {
        ngx_free(val);
        return NGX_ERROR;
    }

    ngx_memcpy(v->data, val, len);

    v->len          = len;
    v->valid        = 1;
    v->no_cacheable = 0;
    v->not_found    = 0;

    ngx_free(val);

    return NGX_OK;

not_found:

    v->not_found = 1;

    return NGX_OK;
}


#if (T_GEO)
static ngx_int_t
ngx_http_geoip_region_variable(ngx_http_request_t        *r,
                               ngx_http_variable_value_t *v, uintptr_t data)
{
    char        *val;
    size_t       len;
    GeoIPRegion *gr;

    ngx_http_geoip_conf_t *gcf;

    gcf = ngx_http_get_module_main_conf(r, ngx_http_geoip_module);

    if (gcf->region == NULL)
    {
        goto not_found;
    }

    gr = GeoIP_region_by_ipnum(gcf->region, ngx_http_geoip_addr(r, gcf));

    if (gr == NULL)
    {
        goto not_found;
    }

    val = (char *)gr + data;
    if (val == NULL)
    {
        goto no_value;
    }

    len     = ngx_strlen(val);
    v->data = ngx_pnalloc(r->pool, len);
    if (v->data == NULL)
    {
        GeoIPRegion_delete(gr);
        return NGX_ERROR;
    }

    ngx_memcpy(v->data, val, len);

    v->len          = len;
    v->valid        = 1;
    v->no_cacheable = 0;
    v->not_found    = 0;

    GeoIPRegion_delete(gr);

    return NGX_OK;

no_value:

    GeoIPRegion_delete(gr);

not_found:

    v->not_found = 1;

    return NGX_OK;
}
#endif


static ngx_int_t
ngx_http_geoip_city_variable(ngx_http_request_t        *r,
                             ngx_http_variable_value_t *v, uintptr_t data)
{
    char        *val;
    size_t       len;
    GeoIPRecord *gr;

    gr = ngx_http_geoip_get_city_record(r);
    if (gr == NULL)
    {
        goto not_found;
    }

    val = *(char **)((char *)gr + data);
    if (val == NULL)
    {
        goto no_value;
    }

    len     = ngx_strlen(val);
    v->data = ngx_pnalloc(r->pool, len);
    if (v->data == NULL)
    {
        GeoIPRecord_delete(gr);
        return NGX_ERROR;
    }

    ngx_memcpy(v->data, val, len);

    v->len          = len;
    v->valid        = 1;
    v->no_cacheable = 0;
    v->not_found    = 0;

    GeoIPRecord_delete(gr);

    return NGX_OK;

no_value:

    GeoIPRecord_delete(gr);

not_found:

    v->not_found = 1;

    return NGX_OK;
}


static ngx_int_t
ngx_http_geoip_region_name_variable(ngx_http_request_t        *r,
                                    ngx_http_variable_value_t *v,
                                    uintptr_t                  data)
{
    size_t       len;
    const char  *val;
    GeoIPRecord *gr;

    gr = ngx_http_geoip_get_city_record(r);
    if (gr == NULL)
    {
        goto not_found;
    }

    val = GeoIP_region_name_by_code(gr->country_code, gr->region);

    GeoIPRecord_delete(gr);

    if (val == NULL)
    {
        goto not_found;
    }

    len     = ngx_strlen(val);
    v->data = ngx_pnalloc(r->pool, len);
    if (v->data == NULL)
    {
        return NGX_ERROR;
    }

    ngx_memcpy(v->data, val, len);

    v->len          = len;
    v->valid        = 1;
    v->no_cacheable = 0;
    v->not_found    = 0;

    return NGX_OK;

not_found:

    v->not_found = 1;

    return NGX_OK;
}


static ngx_int_t
ngx_http_geoip_city_float_variable(ngx_http_request_t        *r,
                                   ngx_http_variable_value_t *v, uintptr_t data)
{
    float        val;
    GeoIPRecord *gr;

    gr = ngx_http_geoip_get_city_record(r);
    if (gr == NULL)
    {
        v->not_found = 1;
        return NGX_OK;
    }

    v->data = ngx_pnalloc(r->pool, NGX_INT64_LEN + 5);
    if (v->data == NULL)
    {
        GeoIPRecord_delete(gr);
        return NGX_ERROR;
    }

    val = *(float *)((char *)gr + data);

    v->len          = ngx_sprintf(v->data, "%.4f", val) - v->data;
    v->valid        = 1;
    v->no_cacheable = 0;
    v->not_found    = 0;

    GeoIPRecord_delete(gr);

    return NGX_OK;
}


static ngx_int_t
ngx_http_geoip_city_int_variable(ngx_http_request_t        *r,
                                 ngx_http_variable_value_t *v, uintptr_t data)
{
    int          val;
    GeoIPRecord *gr;

    gr = ngx_http_geoip_get_city_record(r);
    if (gr == NULL)
    {
        v->not_found = 1;
        return NGX_OK;
    }

    v->data = ngx_pnalloc(r->pool, NGX_INT64_LEN);
    if (v->data == NULL)
    {
        GeoIPRecord_delete(gr);
        return NGX_ERROR;
    }

    val = *(int *)((char *)gr + data);

    v->len          = ngx_sprintf(v->data, "%d", val) - v->data;
    v->valid        = 1;
    v->no_cacheable = 0;
    v->not_found    = 0;

    GeoIPRecord_delete(gr);

    return NGX_OK;
}


static GeoIPRecord *
ngx_http_geoip_get_city_record(ngx_http_request_t *r)
{
    ngx_http_geoip_conf_t *gcf;

    gcf = ngx_http_get_module_main_conf(r, ngx_http_geoip_module);

    if (gcf->city)
    {
#if (NGX_HAVE_GEOIP_V6)
        return gcf->city_v6
                   ? GeoIP_record_by_ipnum_v6(gcf->city,
                                              ngx_http_geoip_addr_v6(r, gcf))
                   : GeoIP_record_by_ipnum(gcf->city,
                                           ngx_http_geoip_addr(r, gcf));
#else
        return GeoIP_record_by_ipnum(gcf->city, ngx_http_geoip_addr(r, gcf));
#endif
    }

    return NULL;
}


static ngx_int_t
ngx_http_geoip_add_variables(ngx_conf_t *cf)
{
    ngx_http_variable_t *var, *v;

    for (v = ngx_http_geoip_vars; v->name.len; v++)
    {
        var = ngx_http_add_variable(cf, &v->name, v->flags);
        if (var == NULL)
        {
            return NGX_ERROR;
        }

        var->get_handler = v->get_handler;
        var->data        = v->data;
    }

    return NGX_OK;
}


static void *
ngx_http_geoip_create_conf(ngx_conf_t *cf)
{
    ngx_pool_cleanup_t    *cln;
    ngx_http_geoip_conf_t *conf;

    conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_geoip_conf_t));
    if (conf == NULL)
    {
        return NULL;
    }

    conf->proxy_recursive = NGX_CONF_UNSET;

    cln = ngx_pool_cleanup_add(cf->pool, 0);
    if (cln == NULL)
    {
        return NULL;
    }

    cln->handler = ngx_http_geoip_cleanup;
    cln->data    = conf;

    return conf;
}


static char *
ngx_http_geoip_init_conf(ngx_conf_t *cf, void *conf)
{
    ngx_http_geoip_conf_t *gcf = conf;

    ngx_conf_init_value(gcf->proxy_recursive, 0);

    return NGX_CONF_OK;
}


static char *
ngx_http_geoip_country(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
{
    ngx_http_geoip_conf_t *gcf = conf;

    ngx_str_t *value;

    if (gcf->country)
    {
        return "is duplicate";
    }

    value = cf->args->elts;

    gcf->country = GeoIP_open((char *)value[1].data, GEOIP_MEMORY_CACHE);

    if (gcf->country == NULL)
    {
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "GeoIP_open(\"%V\") failed",
                           &value[1]);

        return NGX_CONF_ERROR;
    }

    if (cf->args->nelts == 3)
    {
        if (ngx_strcmp(value[2].data, "utf8") == 0)
        {
            GeoIP_set_charset(gcf->country, GEOIP_CHARSET_UTF8);
        }
        else
        {
            ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "invalid parameter \"%V\"",
                               &value[2]);
            return NGX_CONF_ERROR;
        }
    }

    switch (gcf->country->databaseType)
    {
    case GEOIP_COUNTRY_EDITION: return NGX_CONF_OK;

#if (NGX_HAVE_GEOIP_V6)
    case GEOIP_COUNTRY_EDITION_V6: gcf->country_v6 = 1; return NGX_CONF_OK;
#endif

    default:
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
                           "invalid GeoIP database \"%V\" type:%d", &value[1],
                           gcf->country->databaseType);
        return NGX_CONF_ERROR;
    }
}


#if (T_GEO)
static char *
ngx_http_geoip_region(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
{
    ngx_http_geoip_conf_t *gcf = conf;

    ngx_str_t *value;

    if (gcf->region)
    {
        return "is duplicate";
    }

    value = cf->args->elts;

    gcf->region = GeoIP_open((char *)value[1].data, GEOIP_MEMORY_CACHE);

    if (gcf->region == NULL)
    {
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "GeoIP_open(\"%V\") failed",
                           &value[1]);

        return NGX_CONF_ERROR;
    }

    if (cf->args->nelts == 3)
    {
        if (ngx_strcmp(value[2].data, "utf8") == 0)
        {
            GeoIP_set_charset(gcf->region, GEOIP_CHARSET_UTF8);
        }
        else
        {
            ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "invalid parameter \"%V\"",
                               &value[2]);
            return NGX_CONF_ERROR;
        }
    }

    switch (gcf->region->databaseType)
    {
    case GEOIP_REGION_EDITION_REV0:
    case GEOIP_REGION_EDITION_REV1: return NGX_CONF_OK;
    default:
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
                           "invalid GeoIP database \"%V\" type:%d", &value[1],
                           gcf->region->databaseType);
        return NGX_CONF_ERROR;
    }
}
#endif


static char *
ngx_http_geoip_org(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
{
    ngx_http_geoip_conf_t *gcf = conf;

    ngx_str_t *value;

    if (gcf->org)
    {
        return "is duplicate";
    }

    value = cf->args->elts;

    gcf->org = GeoIP_open((char *)value[1].data, GEOIP_MEMORY_CACHE);

    if (gcf->org == NULL)
    {
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "GeoIP_open(\"%V\") failed",
                           &value[1]);

        return NGX_CONF_ERROR;
    }

    if (cf->args->nelts == 3)
    {
        if (ngx_strcmp(value[2].data, "utf8") == 0)
        {
            GeoIP_set_charset(gcf->org, GEOIP_CHARSET_UTF8);
        }
        else
        {
            ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "invalid parameter \"%V\"",
                               &value[2]);
            return NGX_CONF_ERROR;
        }
    }

    switch (gcf->org->databaseType)
    {
    case GEOIP_ISP_EDITION:
    case GEOIP_ORG_EDITION:
    case GEOIP_DOMAIN_EDITION:
    case GEOIP_ASNUM_EDITION: return NGX_CONF_OK;

#if (NGX_HAVE_GEOIP_V6)
    case GEOIP_ISP_EDITION_V6:
    case GEOIP_ORG_EDITION_V6:
    case GEOIP_DOMAIN_EDITION_V6:
    case GEOIP_ASNUM_EDITION_V6: gcf->org_v6 = 1; return NGX_CONF_OK;
#endif

    default:
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
                           "invalid GeoIP database \"%V\" type:%d", &value[1],
                           gcf->org->databaseType);
        return NGX_CONF_ERROR;
    }
}


static char *
ngx_http_geoip_city(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
{
    ngx_http_geoip_conf_t *gcf = conf;

    ngx_str_t *value;

    if (gcf->city)
    {
        return "is duplicate";
    }

    value = cf->args->elts;

    gcf->city = GeoIP_open((char *)value[1].data, GEOIP_MEMORY_CACHE);

    if (gcf->city == NULL)
    {
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "GeoIP_open(\"%V\") failed",
                           &value[1]);

        return NGX_CONF_ERROR;
    }

    if (cf->args->nelts == 3)
    {
        if (ngx_strcmp(value[2].data, "utf8") == 0)
        {
            GeoIP_set_charset(gcf->city, GEOIP_CHARSET_UTF8);
        }
        else
        {
            ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "invalid parameter \"%V\"",
                               &value[2]);
            return NGX_CONF_ERROR;
        }
    }

    switch (gcf->city->databaseType)
    {
    case GEOIP_CITY_EDITION_REV0:
    case GEOIP_CITY_EDITION_REV1: return NGX_CONF_OK;

#if (NGX_HAVE_GEOIP_V6)
    case GEOIP_CITY_EDITION_REV0_V6:
    case GEOIP_CITY_EDITION_REV1_V6: gcf->city_v6 = 1; return NGX_CONF_OK;
#endif

    default:
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0,
                           "invalid GeoIP City database \"%V\" type:%d",
                           &value[1], gcf->city->databaseType);
        return NGX_CONF_ERROR;
    }
}


static char *
ngx_http_geoip_proxy(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
{
    ngx_http_geoip_conf_t *gcf = conf;

    ngx_str_t *value;
    ngx_cidr_t cidr, *c;

    value = cf->args->elts;

    if (ngx_http_geoip_cidr_value(cf, &value[1], &cidr) != NGX_OK)
    {
        return NGX_CONF_ERROR;
    }

    if (gcf->proxies == NULL)
    {
        gcf->proxies = ngx_array_create(cf->pool, 4, sizeof(ngx_cidr_t));
        if (gcf->proxies == NULL)
        {
            return NGX_CONF_ERROR;
        }
    }

    c = ngx_array_push(gcf->proxies);
    if (c == NULL)
    {
        return NGX_CONF_ERROR;
    }

    *c = cidr;

    return NGX_CONF_OK;
}

static ngx_int_t
ngx_http_geoip_cidr_value(ngx_conf_t *cf, ngx_str_t *net, ngx_cidr_t *cidr)
{
    ngx_int_t rc;

    if (ngx_strcmp(net->data, "255.255.255.255") == 0)
    {
        cidr->family    = AF_INET;
        cidr->u.in.addr = 0xffffffff;
        cidr->u.in.mask = 0xffffffff;

        return NGX_OK;
    }

    rc = ngx_ptocidr(net, cidr);

    if (rc == NGX_ERROR)
    {
        ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, "invalid network \"%V\"", net);
        return NGX_ERROR;
    }

    if (rc == NGX_DONE)
    {
        ngx_conf_log_error(NGX_LOG_WARN, cf, 0,
                           "low address bits of %V are meaningless", net);
    }

    return NGX_OK;
}


static void
ngx_http_geoip_cleanup(void *data)
{
    ngx_http_geoip_conf_t *gcf = data;

    if (gcf->country)
    {
        GeoIP_delete(gcf->country);
    }

#if (T_GEO)
    if (gcf->region)
    {
        GeoIP_delete(gcf->region);
    }
#endif

    if (gcf->org)
    {
        GeoIP_delete(gcf->org);
    }

    if (gcf->city)
    {
        GeoIP_delete(gcf->city);
    }
}
